package com.codeduck.kafka.kafka.consumer;

import com.codeduck.kafka.pojo.TopicHandler;
import org.apache.kafka.common.TopicPartition;

import java.util.List;
import java.util.Properties;

/**
 * @author: <a href="mailto:codeduck@163.com">Codeduck</a>
 * @date: 2023/3/4
 */
public interface IMessageConsumer {

    void subscribe(Properties properties, TopicHandler topicHandler);

    void subscribe(Properties properties, List<String> topics);

    void assign(Properties properties, List<TopicPartition> topicPartitions);

}
